package com.ecube.mqtt;

import com.ecube.mqtt.mysql.Query;
import org.junit.Test;

import java.math.BigInteger;
import java.text.SimpleDateFormat;
import java.util.Date;

public class ChargeSend {
    @Test
    public void start() throws InterruptedException {

        //非常变参数
        String env = "UAT";
        String externalCode = "110093";
        String gunNo = "2";
        String chgID = "1100930001000001";
        String index = Query.getChargeSnno(env, chgID);
        Date date = new Date();
        SimpleDateFormat dateFormat= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        //启动充电
        Boolean sendStart = MqttUtils.sendStartChargeMQTT(env, externalCode, index, chgID, gunNo, dateFormat.format(date), "");
        Thread.sleep(5000);
        //实时数据
        Boolean sendRealData = MqttUtils.sendRealDataMQTT(env, externalCode, chgID, gunNo, "30.5");
        if(sendStart && sendRealData){
            System.out.println("充电启动成功");
        }else {
            System.out.println("充电启动失败");
        }

    }

//    @Test
//    public void end() throws InterruptedException {
//        //常变参数
//        String index = "229";
//
//
//        //非常变参数
//        String env = "UAT";
//        String chgID = "1100930001000001";
//        String externalCode = "110093";
//        String gunNo = "2";
//        String plateNo = "豫A000000";
//        String vin = "Yh821214354323424";
//        Date date = new Date();
//        SimpleDateFormat dateFormat= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        //结束充电
//        Boolean sendEndCharge = MqttUtils.sendEndChargeMQTT(env, externalCode, index, chgID, gunNo, dateFormat.format(date));
//        Thread.sleep(10000);
//        //实时数据
//        Boolean sendChargeResult =  MqttUtils.sendChargeResultMQTT(env, externalCode, index, gunNo, plateNo);
//        if(sendEndCharge && sendChargeResult){
//            System.out.println("充电结束成功");
//        }else {
//            System.out.println("充电结束失败");
//        }
//
//    }


}
